package com.sunchangpeng.rocketmq.remoting.netty;

import lombok.Data;

@Data
public class NettyClientConfig {
    private int clientWorkerThreads = 4;
    private int clientCallbackExecutorThreads = Runtime.getRuntime().availableProcessors();

    private int clientOnewaySemaphoreValue = NettySystemConfig.CLIENT_ONEWAY_SEMAPHORE_VALUE;
    private int clientAsyncSemaphoreValue = NettySystemConfig.CLIENT_ASYNC_SEMAPHORE_VALUE;

    private int connectTimeoutMillis = 3000;

    private int clientSocketSndBufSize = NettySystemConfig.socketSndbufSize;
    private int clientSocketRcvBufSize = NettySystemConfig.socketRcvbufSize;

    private boolean useTLS;

    private int clientChannelMaxIdleTimeSeconds = 120;

    private boolean clientCloseSocketIfTimeout = false;
}
